package com.charmzenus.message.kafka;


import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.stereotype.Component;

@Component
public class MyConsumer {

//    @KafkaListener(topics = {"happy"})
//    public void topic_AuthorityRole(ConsumerRecord<String, String> record, Acknowledgment ack) throws Exception {
//
//        System.out.println(record.value());
//        ack.acknowledge();
//    }
}
